package com.java.code.kafka;

import java.io.Serializable;
import java.util.Map;

/**
 * @author weichuanyuan
 * @e-mail wei.cy@bsoft.com.cn
 * @date 2021/10/19 21:36
 * @package com.java.code.kafka
 * @description
 */

public class MQMessage<T> implements Serializable {
    private static final long serialVersionUID = 1168805710503357509L;
    private String id;
    private long timestamp;
    private String topic;
    private String tag;
    private Map<String, Object> headers;
    private T content;

    public MQMessage() {
    }

    public String getId() {
        return this.id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public long getTimestamp() {
        return this.timestamp;
    }

    public void setTimestamp(long timestamp) {
        this.timestamp = timestamp;
    }

    public String getTopic() {
        return this.topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public Map<String, Object> getHeaders() {
        return this.headers;
    }

    public void setHeaders(Map<String, Object> headers) {
        this.headers = headers;
    }

    public T getContent() {
        return this.content;
    }

    public void setContent(T content) {
        this.content = content;
    }

    public String getTag() {
        return this.tag;
    }

    public void setTag(String tag) {
        this.tag = tag;
    }
}
